package cn.lingyangwl.agile.pay.pay.channel.wxpay;

import cn.lingyangwl.framework.tool.core.exception.BizException;
import cn.lingyangwl.agile.pay.pay.channel.AbstractChannelRefundNoticeService;
import cn.lingyangwl.agile.pay.common.constants.Cs;
import cn.lingyangwl.agile.pay.constant.IfCodeEnum;
import cn.lingyangwl.agile.pay.common.exception.ResponseException;
import cn.lingyangwl.agile.pay.model.entity.RefundOrder;
import cn.lingyangwl.agile.pay.common.service.RefundOrderService;
import cn.lingyangwl.agile.pay.common.utils.AmountUtils;
import cn.lingyangwl.agile.pay.pay.model.bo.MchAppConfigContext;
import cn.lingyangwl.agile.pay.pay.model.bo.WxServiceWrapper;
import cn.lingyangwl.agile.pay.pay.model.params.wxpay.WxpayIsvParams;
import cn.lingyangwl.agile.pay.pay.model.params.wxpay.WxpayNormalMchParams;
import cn.lingyangwl.agile.pay.pay.model.rqrs.ChannelRetMsgExt;
import com.alibaba.fastjson2.JSONObject;
import com.github.binarywang.wxpay.bean.notify.SignatureHeader;
import com.github.binarywang.wxpay.bean.notify.WxPayRefundNotifyResult;
import com.github.binarywang.wxpay.bean.notify.WxPayRefundNotifyV3Result;
import com.github.binarywang.wxpay.config.WxPayConfig;
import com.github.binarywang.wxpay.service.WxPayService;
import com.github.binarywang.wxpay.v3.auth.AutoUpdateCertificatesVerifier;
import com.github.binarywang.wxpay.v3.auth.PrivateKeySigner;
import com.github.binarywang.wxpay.v3.auth.WxPayCredentials;
import com.github.binarywang.wxpay.v3.util.PemUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.tuple.MutablePair;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.security.PrivateKey;

/**
 * 微信支付 退款回调接口实现类
 *
 * @author shenguangyang
 */
@Service
@Slf4j
public class WxpayChannelRefundNoticeService extends AbstractChannelRefundNoticeService {

    @Resource
    private RefundOrderService refundOrderService;

    @Override
    public IfCodeEnum getIfCode() {
        return IfCodeEnum.WXPAY;
    }

    @Override
    public MutablePair<String, Object> parseParams(HttpServletRequest request, String urlOrderNo, NoticeTypeEnum noticeTypeEnum) {
        try {
            // 获取订单信息
            RefundOrder refundOrder = refundOrderService.getById(urlOrderNo);
            if (refundOrder == null) {
                throw new BizException("订单不存在");
            }

            //获取支付参数 (缓存数据) 和 商户信息
            MchAppConfigContext mchAppConfigContext = configContextQueryService.queryMchInfoAndAppInfo(refundOrder.getMchNo(), refundOrder.getAppId());
            if (mchAppConfigContext == null) {
                throw new BizException("获取商户信息失败");
            }
            String apiVersion = ""; // 接口类型
            String wxKey = "";  // 微信私钥
            String mchType = mchAppConfigContext.getMchType();
            if (Cs.MCH_TYPE_NORMAL.equals(mchType)) {
                WxpayNormalMchParams normalMchParams = (WxpayNormalMchParams) configContextQueryService.queryNormalMchParams(mchAppConfigContext.getMchNo(), mchAppConfigContext.getAppId(), getIfCode());
                apiVersion = normalMchParams.getApiVersion();
                wxKey = Cs.PAY_IF_VERSION.WX_V2.equals(apiVersion) ? normalMchParams.getKey() : normalMchParams.getApiV3Key();
            } else if (Cs.MCH_TYPE_ISVSUB.equals(mchType)) {
                WxpayIsvParams wxpayIsvParams = (WxpayIsvParams) configContextQueryService.queryIsvParams(mchAppConfigContext.getMchInfo().getIsvNo(), getIfCode());
                apiVersion = wxpayIsvParams.getApiVersion();
                wxKey = Cs.PAY_IF_VERSION.WX_V2.equals(apiVersion) ? wxpayIsvParams.getKey() : wxpayIsvParams.getApiV3Key();
            } else {
                throw new BizException("商户类型错误");
            }

            if (Cs.PAY_IF_VERSION.WX_V3.equals(apiVersion)) {     // V3接口回调
                // 验签 && 获取订单回调数据
                WxPayRefundNotifyV3Result.DecryptNotifyResult result = parseOrderNotifyV3Result(request, mchAppConfigContext);
                return MutablePair.of(urlOrderNo, result);

            } else if (Cs.PAY_IF_VERSION.WX_V2.equals(apiVersion)) {     // V2接口回调
                String xmlResult = IOUtils.toString(request.getInputStream(), request.getCharacterEncoding());
                if (StringUtils.isEmpty(xmlResult)) {
                    return null;
                }
                WxPayRefundNotifyResult result = WxPayRefundNotifyResult.fromXML(xmlResult, wxKey);
                return MutablePair.of(urlOrderNo, result.getReqInfo());
            }
            return null;
        } catch (Exception e) {
            log.error("error", e);
            throw ResponseException.buildText("ERROR");
        }
    }

    @Override
    public ChannelRetMsgExt doNotice(HttpServletRequest request, Object params, RefundOrder refundOrder, MchAppConfigContext mchAppConfigContext, NoticeTypeEnum noticeTypeEnum) {
        try {
            ChannelRetMsgExt result = new ChannelRetMsgExt();
            WxServiceWrapper wxServiceWrapper = (WxServiceWrapper) configContextQueryService.getClientWrapper(this.getIfCode(), mchAppConfigContext);

            result.setChannelState(ChannelRetMsgExt.ChannelState.WAITING); // 默认支付中
            if (Cs.PAY_IF_VERSION.WX_V3.equals(wxServiceWrapper.getApiVersion())) {
                WxPayRefundNotifyV3Result.DecryptNotifyResult notifyResult = (WxPayRefundNotifyV3Result.DecryptNotifyResult) params;
                // 验证参数
                verifyWxPay3Params(notifyResult, refundOrder);
                String refundStatus = notifyResult.getRefundStatus();
                if ("SUCCESS".equals(refundStatus)) {
                    result.setChannelState(ChannelRetMsgExt.ChannelState.CONFIRM_SUCCESS);
                } else {  //CHANGE—退款异常， REFUNDCLOSE—退款关闭
                    result.setChannelState(ChannelRetMsgExt.ChannelState.CONFIRM_FAIL); //退款失败
                }
                result.setChannelOrderId(notifyResult.getTransactionId()); // 渠道订单号

                JSONObject resJSON = new JSONObject();
                resJSON.put("code", "SUCCESS");
                resJSON.put("message", "成功");

                ResponseEntity<?> okResponse = jsonResp(resJSON);
                result.setResponseEntity(okResponse); //响应数据
            } else {
                result.setChannelState(ChannelRetMsgExt.ChannelState.CONFIRM_FAIL); //退款失败
            }
            return result;
        } catch (Exception e) {
            log.error("error", e);
            throw ResponseException.buildText("ERROR");
        }
    }

    /**
     * V3校验通知签名
     *
     * @param request             请求信息
     * @param mchAppConfigContext 商户配置
     * @return true:校验通过 false:校验不通过
     */
    private WxPayRefundNotifyV3Result.DecryptNotifyResult parseOrderNotifyV3Result(HttpServletRequest request, MchAppConfigContext mchAppConfigContext) throws Exception {
        SignatureHeader header = new SignatureHeader();
        header.setTimeStamp(request.getHeader("Wechatpay-Timestamp"));
        header.setNonce(request.getHeader("Wechatpay-Nonce"));
        header.setSerial(request.getHeader("Wechatpay-Serial"));
        header.setSignature(request.getHeader("Wechatpay-Signature"));

        // 获取加密信息
        String params = getReqParamFromBody();

        log.info("\n【请求头信息】：{}\n【加密数据】：{}", header.toString(), params);

        WxPayService wxPayService = ((WxServiceWrapper) configContextQueryService.getClientWrapper(this.getIfCode(), mchAppConfigContext))
                .getWxPayService();
        WxPayConfig wxPayConfig = wxPayService.getConfig();
        // 自动获取微信平台证书
        PrivateKey privateKey = PemUtils.loadPrivateKey(Files.newInputStream(Paths.get(wxPayConfig.getPrivateKeyPath())));
        AutoUpdateCertificatesVerifier verifier = new AutoUpdateCertificatesVerifier(
                new WxPayCredentials(wxPayConfig.getMchId(), new PrivateKeySigner(wxPayConfig.getCertSerialNo(), privateKey)),
                wxPayConfig.getApiV3Key().getBytes(StandardCharsets.UTF_8));
        wxPayConfig.setVerifier(verifier);
        wxPayService.setConfig(wxPayConfig);

        WxPayRefundNotifyV3Result result = wxPayService.parseRefundNotifyV3Result(params, header);

        return result.getResult();
    }

    /**
     * V3接口验证微信支付通知参数
     */
    public void verifyWxPay3Params(WxPayRefundNotifyV3Result.DecryptNotifyResult result, RefundOrder refundOrder) {

        try {
            // 核对金额
            long wxPayAmt = result.getAmount().getRefund();
            BigDecimal dbPayAmt = refundOrder.getRefundAmount();
            if (AmountUtils.yuanToFen(dbPayAmt).longValue() != wxPayAmt) {
                throw ResponseException.buildText("AMOUNT ERROR");
            }
        } catch (Exception e) {
            throw ResponseException.buildText("ERROR");
        }
    }
//
//    /**
//     * V2接口验证微信支付通知参数
//     * @return
//     */
//    public void verifyWxPay2Params(WxPayRefundNotifyResult.ReqInfo result, RefundOrder refundOrder) {
//
//        try {
//            // 核对金额
//            Integer total_fee = result.getRefundFee();  // 退款金额
//            long wxPayAmt = new BigDecimal(total_fee).longValue();
//            long dbPayAmt = refundOrder.getRefundAmount().longValue();
//            if (dbPayAmt != wxPayAmt) {
//                throw ResponseException.buildText("AMOUNT ERROR");
//            }
//        } catch (Exception e) {
//            throw ResponseException.buildText("ERROR");
//        }
//    }
}
